545994abd718724e5f016c810da43abc72b4c9e1,components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/streaming/FilterConsumer.java,FilterConsumer,FilterConsumer,#TwitterEndpoint#,31
Before Change
super(te);
TwitterStream twitterStream = new TwitterStreamFactory(te.getProperties().getConfiguration()).getInstance();
twitterStream.addListener(this);
FilterQuery filterQuery = createFilter(te);
twitterStream.filter(filterQuery);
}
After Change
public FilterConsumer(TwitterEndpoint te) {
super(te);
twitterStream.filter(createFilter(te));
}
private FilterQuery createFilter(TwitterEndpoint te) {